package com.pengheng.service.impl;

import com.pengheng.bean.WaterSensor;
import com.pengheng.service.ITrafficIndicatorAlgorithm;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;


/**
 * 附近有大车
 */
@Deprecated
public class LargeCarNearByTrafficIndicatorAlgorithm implements ITrafficIndicatorAlgorithm {


    /**
     * @param singleOutputStreamOperator
     * @throws ClassNotFoundException
     */
    @Override
    public void algorithm(SingleOutputStreamOperator<WaterSensor> singleOutputStreamOperator) throws Exception {
        System.out.println("大车计算逻辑");
    }
}
